﻿using System;
using eNets.IO.Buf;

namespace eNets.CBK.Pipe;

public interface IPipeReader<T> : IReadableBuffer<T>
{
    void AddListener(Action listener);
    
    void RcvAsync();

    void Flush();
}